package com.sanmubird.mywebframework.eventbus.core;

/**
 * 消息消费者。负责从 Broker 中获取消息，并进行相应处理
 */
public interface MqObserver<T> {
    String getRoutingKey();

    void observe(MqMessage<T> mqMessage);

}
